package com.lansetech.framework.redis.peak.shaving;

public class DefaultMessageConsumer implements MessageConsumer {

    @Override
    public void consume(String type, String value) {
        System.out.println(Thread.currentThread().getName() + ":" + type + ":" + value);
    }

    @Override
    public void handleFailure(String type, String value, Exception e) {
        e.printStackTrace();
    }
}
